package com.keiou.drink.api.rx;

import rx.Observable;
import rx.android.schedulers.AndroidSchedulers;
import rx.schedulers.Schedulers;

/**
 * 作者 ：Bob on 2017/10/10.
 * 邮箱 ：motherlovefather@126.com
 */

public class RxHelper {

    public static <T> rx.Observable.Transformer<T, T> applySchedulers() {
        return observable -> observable.subscribeOn(Schedulers.io())
                .observeOn(AndroidSchedulers.mainThread());
    }
}
